Node / ReticulumProjects / MeshChatX.git / files / meshchatx / src / frontend / js / relayMessageTimeline.js

Displaying Raw • Download

T8b949e// SPDX-License-Identifier: 0BSD AND MIT

Tff7b72import Tb4b4b4{ Te6edf3calendarDayKeyFromDate Tb4b4b4} Tff7b72from Ta5d6ff"./messageTimestampGrouping.js"Tb4b4b4;

T8b949e/**

* @param {object} msg

* @returns {string}

*/

Tff7b72export Tff7b72function Te6edf3relayMessageKeyTb4b4b4(Te6edf3msgTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3msgTb4b4b4) Tb4b4b4{

Tff7b72return Ta5d6ff""Tb4b4b4;

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3msgTb4b4b4.Te6edf3seq Tff7b72!= Tff7b72null Tff7b72&& Te6edf3msgTb4b4b4.Te6edf3seq Tff7b72!== Ta5d6ff""Tb4b4b4) Tb4b4b4{

Tff7b72return Ta5d6ff`Ta5d6ffseq-Tffd700${Te6edf3msgTb4b4b4.Te6edf3seqTffd700}Ta5d6ff`Tb4b4b4;

Tb4b4b4}

Tff7b72const Te6edf3src Tff7b72= Te6edf3msgTb4b4b4.Te6edf3src Tff7b72|| Ta5d6ff""Tb4b4b4;

Tff7b72const Te6edf3text Tff7b72= Tff7b72typeof Te6edf3msgTb4b4b4.Te6edf3text Tff7b72=== Ta5d6ff"string" Tff7b72? Te6edf3msgTb4b4b4.Te6edf3text Tff7b72: Ta5d6ff""Tb4b4b4;

T8b949e// Keep keys attribute-safe: never embed raw message text (XSS-shaped payloads).

Tff7b72const Te6edf3textFrag Tff7b72= Tffa657encodeURIComponentTb4b4b4(Te6edf3textTb4b4b4.Te6edf3sliceTb4b4b4(T79c0ff0Tb4b4b4, T79c0ff24Tb4b4b4)Tb4b4b4)Tb4b4b4;

Tff7b72return Ta5d6ff`Tffd700${Te6edf3msgTb4b4b4.Te6edf3kind Tff7b72|| Ta5d6ff"msg"Tffd700}Ta5d6ff-Tffd700${Te6edf3msgTb4b4b4.Te6edf3ts Tff7b72|| T79c0ff0Tffd700}Ta5d6ff-Tffd700${Te6edf3srcTffd700}Ta5d6ff-Tffd700${Te6edf3textTb4b4b4.Te6edf3lengthTffd700}Ta5d6ff-Tffd700${Te6edf3textFragTffd700}Ta5d6ff`Tb4b4b4;

Tb4b4b4}

T8b949e/**

* True when an incoming relay message is already present in the list.

* Prefers seq; falls back to kind/ts/src/text for older payloads without seq.

* @param {object[]} messages

* @param {object} incoming

* @returns {boolean}

*/

Tff7b72export Tff7b72function Te6edf3relayMessageAlreadyPresentTb4b4b4(Te6edf3messagesTb4b4b4, Te6edf3incomingTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72!Tffa657ArrayTb4b4b4.Te6edf3isArrayTb4b4b4(Te6edf3messagesTb4b4b4) Tff7b72|| Tff7b72!Te6edf3incomingTb4b4b4) Tb4b4b4{

Tff7b72return Tff7b72falseTb4b4b4;

Tb4b4b4}

Tff7b72const Te6edf3incomingSeq Tff7b72= Te6edf3incomingTb4b4b4.Te6edf3seqTb4b4b4;

Tff7b72if Tb4b4b4(Te6edf3incomingSeq Tff7b72!= Tff7b72null Tff7b72&& Te6edf3incomingSeq Tff7b72!== Ta5d6ff""Tb4b4b4) Tb4b4b4{

Tff7b72return Te6edf3messagesTb4b4b4.Te6edf3someTb4b4b4(Tb4b4b4(Te6edf3mTb4b4b4) Tb4b4b4=> Te6edf3m Tff7b72&& Te6edf3mTb4b4b4.Te6edf3seq Tff7b72=== Te6edf3incomingSeqTb4b4b4)Tb4b4b4;

Tb4b4b4}

Tff7b72const Te6edf3key Tff7b72= Te6edf3relayMessageKeyTb4b4b4(Te6edf3incomingTb4b4b4)Tb4b4b4;

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3keyTb4b4b4) Tb4b4b4{

Tff7b72return Tff7b72falseTb4b4b4;

Tb4b4b4}

Tff7b72return Te6edf3messagesTb4b4b4.Te6edf3someTb4b4b4(Tb4b4b4(Te6edf3mTb4b4b4) Tb4b4b4=> Te6edf3relayMessageKeyTb4b4b4(Te6edf3mTb4b4b4) Tff7b72=== Te6edf3keyTb4b4b4)Tb4b4b4;

Tb4b4b4}

T8b949e/**

* Append extras that are not already represented in base (by seq / fallback key).

* @param {object[]} base

* @param {object[]} extras

* @returns {object[]}

*/

Tff7b72export Tff7b72function Te6edf3mergeRelayMessagesTb4b4b4(Te6edf3baseTb4b4b4, Te6edf3extrasTb4b4b4) Tb4b4b4{

Tff7b72const Te6edf3out Tff7b72= Tffa657ArrayTb4b4b4.Te6edf3isArrayTb4b4b4(Te6edf3baseTb4b4b4) Tff7b72? Tb4b4b4[Tb4b4b4...Te6edf3baseTb4b4b4] Tff7b72: Tb4b4b4[Tb4b4b4]Tb4b4b4;

Tff7b72if Tb4b4b4(Tff7b72!Tffa657ArrayTb4b4b4.Te6edf3isArrayTb4b4b4(Te6edf3extrasTb4b4b4) Tff7b72|| Te6edf3extrasTb4b4b4.Te6edf3length Tff7b72=== T79c0ff0Tb4b4b4) Tb4b4b4{

Tff7b72return Te6edf3outTb4b4b4;

Tb4b4b4}

Tff7b72for Tb4b4b4(Tff7b72const Te6edf3msg Tff7b72of Te6edf3extrasTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3msg Tff7b72&& Tff7b72!Te6edf3relayMessageAlreadyPresentTb4b4b4(Te6edf3outTb4b4b4, Te6edf3msgTb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3outTb4b4b4.Te6edf3pushTb4b4b4(Te6edf3msgTb4b4b4)Tb4b4b4;

Tb4b4b4}

Tb4b4b4}

Tff7b72return Te6edf3outTb4b4b4;

Tb4b4b4}

Tff7b72const Te6edf3CONNECTION_EVENT_TEXTS Tff7b72= Tff7b72new Tffa657SetTb4b4b4(Tb4b4b4[Ta5d6ff"Connection lost"Tb4b4b4, Ta5d6ff"Disconnected from hub"Tb4b4b4, Ta5d6ff"Reconnected to hub"Tb4b4b4]Tb4b4b4)Tb4b4b4;

T8b949e/**

* Join/leave/connection system lines produced by the RRC client.

* @param {object} msg

* @returns {boolean}

*/

Tff7b72export Tff7b72function Te6edf3isRelayPresenceSystemMessageTb4b4b4(Te6edf3msgTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3msg Tff7b72|| Te6edf3msgTb4b4b4.Te6edf3kind Tff7b72!== Ta5d6ff"system"Tb4b4b4) Tb4b4b4{

Tff7b72return Tff7b72falseTb4b4b4;

Tb4b4b4}

Tff7b72const Te6edf3text Tff7b72= Tff7b72typeof Te6edf3msgTb4b4b4.Te6edf3text Tff7b72=== Ta5d6ff"string" Tff7b72? Te6edf3msgTb4b4b4.Te6edf3textTb4b4b4.Te6edf3trimTb4b4b4(Tb4b4b4) Tff7b72: Ta5d6ff""Tb4b4b4;

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3textTb4b4b4) Tb4b4b4{

Tff7b72return Tff7b72falseTb4b4b4;

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3CONNECTION_EVENT_TEXTSTb4b4b4.Te6edf3hasTb4b4b4(Te6edf3textTb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72return Tff7b72trueTb4b4b4;

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3textTb4b4b4.Te6edf3endsWithTb4b4b4(Ta5d6ff" joined"Tb4b4b4) Tff7b72|| Te6edf3textTb4b4b4.Te6edf3endsWithTb4b4b4(Ta5d6ff" left"Tb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72return Tff7b72trueTb4b4b4;

Tb4b4b4}

Tff7b72return Ta5d6ff/^You (?:re)?joined #/iTb4b4b4.Te6edf3testTb4b4b4(Te6edf3textTb4b4b4)Tb4b4b4;

Tb4b4b4}

T8b949e/**

* @param {object} msg

* @returns {"joined"|"left"|"connection"}

*/

Tff7b72export Tff7b72function Te6edf3relayPresenceEventKindTb4b4b4(Te6edf3msgTb4b4b4) Tb4b4b4{

Tff7b72const Te6edf3text Tff7b72= Tff7b72typeof Te6edf3msgTff7b72?Tb4b4b4.Te6edf3text Tff7b72=== Ta5d6ff"string" Tff7b72? Te6edf3msgTb4b4b4.Te6edf3textTb4b4b4.Te6edf3trimTb4b4b4(Tb4b4b4) Tff7b72: Ta5d6ff""Tb4b4b4;

Tff7b72if Tb4b4b4(Te6edf3CONNECTION_EVENT_TEXTSTb4b4b4.Te6edf3hasTb4b4b4(Te6edf3textTb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72return Ta5d6ff"connection"Tb4b4b4;

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3textTb4b4b4.Te6edf3endsWithTb4b4b4(Ta5d6ff" left"Tb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72return Ta5d6ff"left"Tb4b4b4;

Tb4b4b4}

Tff7b72return Ta5d6ff"joined"Tb4b4b4;

Tb4b4b4}

T8b949e/**

* @param {object[]} presenceMessages

* @returns {{ type: string, id: string, messages: object[], joinedCount: number, leftCount: number, connectionCount: number }}

*/

Tff7b72function Te6edf3buildPresenceGroupTb4b4b4(Te6edf3presenceMessagesTb4b4b4) Tb4b4b4{

Tff7b72let Te6edf3joinedCount Tff7b72= T79c0ff0Tb4b4b4;

Tff7b72let Te6edf3leftCount Tff7b72= T79c0ff0Tb4b4b4;

Tff7b72let Te6edf3connectionCount Tff7b72= T79c0ff0Tb4b4b4;

Tff7b72for Tb4b4b4(Tff7b72const Te6edf3msg Tff7b72of Te6edf3presenceMessagesTb4b4b4) Tb4b4b4{

Tff7b72const Te6edf3kind Tff7b72= Te6edf3relayPresenceEventKindTb4b4b4(Te6edf3msgTb4b4b4)Tb4b4b4;

Tff7b72if Tb4b4b4(Te6edf3kind Tff7b72=== Ta5d6ff"left"Tb4b4b4) Tb4b4b4{

Te6edf3leftCount Tff7b72+= T79c0ff1Tb4b4b4;

Tb4b4b4} Tff7b72else Tff7b72if Tb4b4b4(Te6edf3kind Tff7b72=== Ta5d6ff"connection"Tb4b4b4) Tb4b4b4{

Te6edf3connectionCount Tff7b72+= T79c0ff1Tb4b4b4;

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3joinedCount Tff7b72+= T79c0ff1Tb4b4b4;

Tb4b4b4}

Tb4b4b4}

Tff7b72const Te6edf3firstKey Tff7b72= Te6edf3relayMessageKeyTb4b4b4(Te6edf3presenceMessagesTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4)Tb4b4b4;

Tff7b72return Tb4b4b4{

Te6edf3typeTff7b72: Ta5d6ff"presenceGroup"Tb4b4b4,

Te6edf3idTff7b72: Te6edf3firstKey Tff7b72|| Ta5d6ff`Ta5d6ffpresence-Tffd700${Te6edf3presenceMessagesTb4b4b4.Te6edf3lengthTffd700}Ta5d6ff`Tb4b4b4,

Te6edf3messagesTff7b72: Te6edf3presenceMessagesTb4b4b4,

Te6edf3joinedCountTb4b4b4,

Te6edf3leftCountTb4b4b4,

Te6edf3connectionCountTb4b4b4,

Tb4b4b4}Tb4b4b4;

Tb4b4b4}

T8b949e/**

* @param {object[]} messages

* @returns {{ type: string, dayKey?: string, msg?: object, id?: string, messages?: object[], joinedCount?: number, leftCount?: number, connectionCount?: number }[]}

*/

Tff7b72export Tff7b72function Te6edf3buildRelayMessageTimelineTb4b4b4(Te6edf3messagesTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72!Tffa657ArrayTb4b4b4.Te6edf3isArrayTb4b4b4(Te6edf3messagesTb4b4b4) Tff7b72|| Te6edf3messagesTb4b4b4.Te6edf3length Tff7b72=== T79c0ff0Tb4b4b4) Tb4b4b4{

Tff7b72return Tb4b4b4[Tb4b4b4]Tb4b4b4;

Tb4b4b4}

Tff7b72const Te6edf3out Tff7b72= Tb4b4b4[Tb4b4b4]Tb4b4b4;

Tff7b72let Te6edf3prevDayKey Tff7b72= Tff7b72nullTb4b4b4;

T8b949e/** @type {object[]} */

Tff7b72let Te6edf3presenceBuffer Tff7b72= Tb4b4b4[Tb4b4b4]Tb4b4b4;

Tff7b72const Te6edf3flushPresence Tff7b72= Tb4b4b4(Tb4b4b4) Tb4b4b4=> Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3presenceBufferTb4b4b4.Te6edf3length Tff7b72=== T79c0ff0Tb4b4b4) Tb4b4b4{

Tff7b72returnTb4b4b4;

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3presenceBufferTb4b4b4.Te6edf3length Tff7b72=== T79c0ff1Tb4b4b4) Tb4b4b4{

Te6edf3outTb4b4b4.Te6edf3pushTb4b4b4(Tb4b4b4{ Te6edf3typeTff7b72: Ta5d6ff"message"Tb4b4b4, Te6edf3msgTff7b72: Te6edf3presenceBufferTb4b4b4[T79c0ff0Tb4b4b4] Tb4b4b4}Tb4b4b4)Tb4b4b4;

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3outTb4b4b4.Te6edf3pushTb4b4b4(Te6edf3buildPresenceGroupTb4b4b4(Te6edf3presenceBufferTb4b4b4)Tb4b4b4)Tb4b4b4;

Tb4b4b4}

Te6edf3presenceBuffer Tff7b72= Tb4b4b4[Tb4b4b4]Tb4b4b4;

Tb4b4b4}Tb4b4b4;

Tff7b72for Tb4b4b4(Tff7b72const Te6edf3msg Tff7b72of Te6edf3messagesTb4b4b4) Tb4b4b4{

Tff7b72let Te6edf3dayKey Tff7b72= Tff7b72nullTb4b4b4;

Tff7b72if Tb4b4b4(Te6edf3msgTff7b72?Tb4b4b4.Te6edf3ts Tff7b72!= Tff7b72nullTb4b4b4) Tb4b4b4{

Tff7b72const Te6edf3ms Tff7b72= Tff7b72typeof Te6edf3msgTb4b4b4.Te6edf3ts Tff7b72=== Ta5d6ff"number" Tff7b72? Te6edf3msgTb4b4b4.Te6edf3ts Tff7b72: Tffa657NumberTb4b4b4(Te6edf3msgTb4b4b4.Te6edf3tsTb4b4b4)Tb4b4b4;

Tff7b72const Te6edf3d Tff7b72= Tff7b72new Tffa657DateTb4b4b4(Te6edf3msTb4b4b4)Tb4b4b4;

Tff7b72if Tb4b4b4(Tff7b72!Tffa657NumberTb4b4b4.Tffa657isNaNTb4b4b4(Te6edf3dTb4b4b4.Te6edf3getTimeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3dayKey Tff7b72= Te6edf3calendarDayKeyFromDateTb4b4b4(Te6edf3dTb4b4b4)Tb4b4b4;

Tb4b4b4}

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3dayKey Tff7b72&& Te6edf3dayKey Tff7b72!== Te6edf3prevDayKeyTb4b4b4) Tb4b4b4{

Te6edf3flushPresenceTb4b4b4(Tb4b4b4)Tb4b4b4;

Te6edf3outTb4b4b4.Te6edf3pushTb4b4b4(Tb4b4b4{ Te6edf3typeTff7b72: Ta5d6ff"dateDivider"Tb4b4b4, Te6edf3dayKey Tb4b4b4}Tb4b4b4)Tb4b4b4;

Te6edf3prevDayKey Tff7b72= Te6edf3dayKeyTb4b4b4;

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3isRelayPresenceSystemMessageTb4b4b4(Te6edf3msgTb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3presenceBufferTb4b4b4.Te6edf3pushTb4b4b4(Te6edf3msgTb4b4b4)Tb4b4b4;

Tff7b72continueTb4b4b4;

Tb4b4b4}

Te6edf3flushPresenceTb4b4b4(Tb4b4b4)Tb4b4b4;

Te6edf3outTb4b4b4.Te6edf3pushTb4b4b4(Tb4b4b4{ Te6edf3typeTff7b72: Ta5d6ff"message"Tb4b4b4, Te6edf3msg Tb4b4b4}Tb4b4b4)Tb4b4b4;

Tb4b4b4}

Te6edf3flushPresenceTb4b4b4(Tb4b4b4)Tb4b4b4;

Tff7b72return Te6edf3outTb4b4b4;

Tb4b4b4}